package com.guoxin.concurrentprogramming.chapter3.concurrentcy;

import java.util.concurrent.ArrayBlockingQueue;

/**
 * @author Administrator
 */
public class ArrayBlockingQueueDemo {

    public static void main(String[] args) throws InterruptedException {
        ArrayBlockingQueue<Integer> queue = new ArrayBlockingQueue<>(5);
        for(int i=0;i<10;i++){
            queue.offer(i);
        }
        System.out.println(queue);
    }
}
